package com.chis.flink;

import java.io.Serializable;

public class KafkaBean implements Serializable {
    private String kafkatopic;
    private Object kafkavalue;
    private int kafkapart;
    private long kafkaoffset;

    public KafkaBean(String kafkatopic, String kafkavalue, int kafkapart, long kafkaoffset) {
        this.kafkatopic = kafkatopic;
        this.kafkavalue = kafkavalue;
        this.kafkapart = kafkapart;
        this.kafkaoffset = kafkaoffset;
    }

    public String getKafkatopic() {
        return kafkatopic;
    }

    public void setKafkatopic(String kafkatopic) {
        this.kafkatopic = kafkatopic;
    }

    public Object getKafkavalue() {
        return kafkavalue;
    }

    public void setKafkavalue(Object kafkavalue) {
        this.kafkavalue = kafkavalue;
    }

    public int getKafkapart() {
        return kafkapart;
    }

    public void setKafkapart(int kafkapart) {
        this.kafkapart = kafkapart;
    }

    public long getKafkaoffset() {
        return kafkaoffset;
    }

    public void setKafkaoffset(long kafkaoffset) {
        this.kafkaoffset = kafkaoffset;
    }
}
